@火凤凰
3年前 提问
1个回答

java连接数据库的代码

安全小白成长记
3年前

1.连接MySQL数据库

package mysql;

import java.sql.*;

/**
 * @author xys
 */
public class ConnectMysql {
    public static Connection getConnection() throws ClassNotFoundException, SQLException {
        String url = "jdbc:mysql://localhost:3306/databaseName";
        String user = "mysqluser";
        String password = "password";
        String driverClass = "com.mysql.cj.jdbc.Driver";
        Connection connection = null;
        Class.forName(driverClass);
        try {
            connection = DriverManager.getConnection(url, user, password);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        if (connection != null) {
            System.out.println("数据库连接成功");
        } else {
            System.out.println("数据库连接失败");
            connection.close();
        }
        return connection;
    }

    public void getResult() throws ClassNotFoundException, SQLException {
        // 实例化 Statement 对象
        Statement statement = getConnection().createStatement();
        // 要执行的 Mysql 数据库操作语句(增、删、改、查)
        String sql = "";
        // 展开结果集数据库
        ResultSet resultSet = statement.executeQuery(sql);
        while (resultSet.next()) {
            // 通过字段检索
            int id = resultSet.getInt("id");
            String name = resultSet.getString("name");

            // 输出数据
            System.out.println("ID : " +id);
            System.out.println("name :" + name);
        }
        // 完成后需要依次关闭
        resultSet.close();
        statement.close();
        getConnection().close();
    }
}

2.连接Oracle数据库

package cn.zhisheng.test.jdbc;

import oracle.jdbc.driver.OracleDriver;
import java.sql.*;
import java.util.Properties;
/**
 * Created by 10412 on 2016/12/27.
 * JDBC的六大步骤
 * JAVA连接Oracle的三种方式
 */
public class JdbcTest
{
    public static void main(String[] args) {
        Connection connect = null;
        Statement statement = null;
        ResultSet resultSet = null;

        try {
            //第一步:注册驱动
            //第一种方式:类加载(常用)
            //Class.forName("oracle.jdbc.OracleDriver");

            //第二种方式:利用Driver对象
            Driver driver = new OracleDriver();
            DriverManager.deregisterDriver(driver);


            //第二步:获取连接
            //第一种方式:利用DriverManager(常用)
            //connect = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:XE", "你的oracle数据库用户名", "用户名密码");

            //第二种方式:直接使用Driver
            Properties pro = new Properties();
            pro.put("user", "你的oracle数据库用户名");
            pro.put("password", "用户名密码");
            connect = driver.connect("jdbc:oracle:thin:@localhost:1521:XE", pro);

            //测试connect正确与否
            System.out.println(connect);  


            //第三步:获取执行sql语句对象
            //第一种方式:statement
            //statement = connect.createStatement();

            //第二种方式:PreStatement
            PreparedStatement preState = connect.prepareStatement("select  * from tb1_dept where id = ?");


            //第四步:执行sql语句
            //第一种方式:
            //resultSet = statement.executeQuery("select  * from tb1_dept");

            //第二种方式:
            preState.setInt(1, 2);//1是指sql语句中第一个?,  2是指第一个?的values值
            //resultSet = preState.executeQuery();        //执行查询语句
            //查询任何语句,如果有结果集,返回true,没有的话返回false,注意如果是插入一条数据的话,虽然是没有结果集,返回false,但是却能成功的插入一条数据
            boolean execute = preState.execute();
            System.out.println(execute);

            //第五步:处理结果集
            while (resultSet.next())
            {
                int id = resultSet.getInt("id");
                String name = resultSet.getString("name");
                String city = resultSet.getString("city");
                System.out.println(id+"   "+name+"   "+city);  //打印输出结果集
            }
        } catch (Exception e) {
            e.printStackTrace();
        }finally {
            //第六步:关闭资源
                try {
                    if (resultSet!=null) resultSet.close();
                    if (statement!=null) statement.close();
                    if (connect!=null) connect.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
        }
    }
}

3.连接SqlServer数据库


package com.connDBTest;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

public class GetConnectionSqlServer {
    public void getConnectionSqlServer() {

        String driverName = "com.microsoft.jdbc.sqlserver.SQLServerDriver";
        String dbURL = "jdbc:sqlserver://localhost:1433;databasename=USCSecondhandMarketDB"; // 1433是端口,"USCSecondhandMarketDB"是数据库名称
        String userName = "sa"; // 用户名
        String userPwd = "sa"; // 密码

        Connection dbConn = null;
        try {

            Class.forName(driverName).newInstance();
        } catch (Exception ex) {
            System.out.println("驱动加载失败");
            ex.printStackTrace();
        }
        try {
            dbConn = DriverManager.getConnection(dbURL, userName, userPwd);
            System.out.println("成功连接数据库!");
        } catch (Exception e) {
            e.printStackTrace();
        } finally {

            try {
                if (dbConn != null)
                    dbConn.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
    }

    public static void main(String[] args) {
        GetConnectionSqlServer getConn = new GetConnectionSqlServer();
        getConn.getConnectionSqlServer();

    }
}